package com.guqiao.library.base

import com.guqiao.library.utils.Transformer
import io.reactivex.Observable
import java.util.concurrent.TimeUnit


/**
 *
 * @author jiangyao
 * @date 2019-07-19 10:44
 * @des
 */
class ObjectLoader {
    protected fun <T> observe(observable: Observable<T>): Observable<T> {
        return observable.throttleFirst(1, TimeUnit.SECONDS).compose(Transformer.switchSchedulers())
    }
}